package com.springboot.kafka.message.user;

import com.springboot.kafka.message.base.Body;
import lombok.Data;

/**
 * 用户kafka消息类
 *
 * @author supu
 * @create 2019-01-28 17:23
 **/
@Data
public class UserKafka implements Body {

    private static final long serialVersionUID = -2300629698769246733L;

    private Integer id;

    private String name;

    @Override
    public boolean validate() {
        if (this.id == null || this.name == null) {
            return false;
        }
        return true;
    }
}
